package com.pipi.mq.rocketmq.base.consumer;

import com.pipi.mq.rocketmq.base.config.PropertiesConfig;
import org.springframework.stereotype.Component;

/**
 * @Package com.pipi.mq.rocketmq.base
 * @author: 皮皮（pipi@maihaoche.com）
 * @date: 2020/4/18 3:16 PM
 */
@Component
public class OneWayConsumer extends AbstractMQConsumer {

    public OneWayConsumer() {
        setTopic(PropertiesConfig.topicOneWay);
        setTag(PropertiesConfig.tagOneWay);
        setConsumerGroup(PropertiesConfig.consumerGroupOneWay);
    }

    @Override
    public boolean process(Object var1) {
        System.out.println(var1);
        return true;
    }

}
